package io.kiki.sba.registry.api;

import io.kiki.sba.registry.common.model.store.Url;


public interface Client extends Endpoint {


    Channel getChannel(Url url);

    Channel connect(Url url);


    Object sendSync(final Url url, final Object message, final int timeoutMillis);

    void sendWithCallback(final Url url, final Object message, Callback callback, final int timeoutMillis);


    Object sendSync(final Channel channel, final Object message, final int timeoutMillis);
}
